package main

import (
	"emailServer/config"
	"emailServer/server"
	amqp "github.com/rabbitmq/amqp091-go"
	"log"
	"os"
)

func main() {

	// 加载系统环境变量
	env := os.Getenv("GO_ENV")
	if env == "" {
		env = "development"
	}

	// 初始化配置参数
	err := config.InitConfig(env, "./config")
	
	if err != nil {
		log.Fatal(err)
	}

	//config.AMQPInit()

	conn := config.InitAMQPConnection() // 获取连接
	defer func(conn *amqp.Connection) {
		err := conn.Close()
		if err != nil {
			log.Fatal(err)
		}
	}(conn) // 程序退出时关闭连接

	server.StartEmailConsumer(conn)
}
